8d88d98952fcfee47bb8d450758499003e641483,providers/jms/src/java/org/mule/providers/jms/JmsMessageDispatcher.java,JmsMessageDispatcher,dispatchMessage,#UMOEvent#,65
Before Change
String persistentDeliveryString = (String) event.removeProperty("PersistentDelivery");
if (ttlString == null && priorityString == null && persistentDeliveryString == null) {
connector.getJmsSupport().send(producer, msg);
} else {
long ttl = Message.DEFAULT_TIME_TO_LIVE;
int priority = Message.DEFAULT_PRIORITY;
After Change
persistent = Boolean.valueOf(persistentDeliveryString).booleanValue();
}
if (consumer != null && topic) {
//need to register a listener for a topic
Latch l = new Latch();
ReplyToListener listener = new ReplyToListener(l);
consumer.setMessageListener(listener);
connector.getJmsSupport().send(producer, msg, persistent, priority, ttl);
int timeout = event.getEndpoint().getRemoteSyncTimeout();
logger.debug("Waiting for return event for: " + timeout + " ms on " + replyTo);